package com.shark.mq;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @auther shark
 * @create 2024-09-05 23:04
 */
//@Component
public class MyMessageListener4ConfirmSend
{

    public static final String EXCHANGE_DIRECT = "exchange.direct.order";
    public static final String ROUTING_KEY = "order";

    /**
     * 10_生产者端消息确认机制，第一种情况，交换机/路由器都正确
     * 交换机: exchange.direct.order
     * 队列: queue.direct.order
     * 路由词：order
     * @param messageContent
     */
    @RabbitListener(queues = {"queue.direct.order"})
    public void processMessageA(String messageContent) {
        System.out.println("生产者端消息确认机制queue.direct.order info :" + messageContent);
    }
}
